﻿using Common;
using Hangfire;
using Hangfire.Storage;
using PLC.Domain.ScheduledTasks.Job;

namespace PLC.Domain.ScheduledTasks;

public class InitializationScheduledTasks
{
    public static void Init()
    {
        // 初始化的先删除之前的任务  不然启动的时候  会运行之前的任务
        // 如果改了代码  那么可能会报错
        using (var con = JobStorage.Current.GetConnection())
        {
            foreach (var job in con.GetRecurringJobs())
            {
                RecurringJob.RemoveIfExists(job.Id);
            }
        }
        // 启动定时任务
        RecurringJob.AddOrUpdate<IPLCReadAndWriteJob>("PLC-SERVER",p=>p.Work(),CronHelper.EverySecond);
    }
}